Data Fusion / Dataprep

Durante um processo de migração, sua equipe deseja substituir pipelines antigos de ETL baseados em scripts por pipelines no Cloud Data Fusion que façam uso dos serviços de streaming do Google Cloud. Qual plugin do Data Fusion e configuração são mais indicados para ingerir dados em tempo real de um tópico do Pub/Sub para processamento imediato?